package com.ruoyi.project.flink.latest

object TestFlink {
  def main(args: Array[String]): Unit = {

    /*val params = ParameterTool.fromArgs(args)
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    env.getConfig.setGlobalJobParameters(params)
    val consumerProps = new Properties()
    consumerProps.setProperty("bootstrap.servers", "192.168.33.207:9092")
    consumerProps.setProperty("group.id", "test-group")
    consumerProps.setProperty("enable.auto.commit", "false")

    val source = new FlinkKafkaConsumer010[String]("test_1", new SimpleStringSchema(), consumerProps)
    source.setStartFromEarliest()
    val registerStream = env.addSource[String](source)
    registerStream.print()
    env.execute()*/
  }

}
